#include "../../client/rpc_client.hpp"
#include <iostream>       // std::cout, std::endl
#include <thread>         // std::this_thread::sleep_for
#include <chrono>         // std::chrono::seconds

int main()
{
    //实例化发布客服端
    RPC::Client::TopicClient publish_client("127.0.0.1", 9000);
    bool ret = publish_client.topicCreate("news");
    if(ret == false) 
    {
        ERROR_LOG("主题创建失败！");
        return 1;
    }
    std::this_thread::sleep_for(std::chrono::seconds(10));
    
        publish_client.topicPublish("news", "i can achieve！");
    publish_client.shutdown();
    return 0;
}